package com.bujunjie.study.realtime.dwd.db.app;

import com.bujunjie.study.realtime.common.base.BaseSQLApp;
import com.bujunjie.study.realtime.common.constant.FlinkConstant;
import org.apache.flink.table.api.bridge.java.StreamTableEnvironment;

/**
 * <p>交易订单退订成功详情</p>
 *
 * @author bu.junjie
 * @version 1.0.0
 * @createTime 2025/9/17 16:37
 */
public class DwdTradeRefundPaySucDetail  extends BaseSQLApp {

    public static void main(String[] args) {
        new DwdTradeRefundPaySucDetail().start(
                10018,
                4,
                FlinkConstant.TOPIC_DWD_TRADE_REFUND_PAYMENT_SUCCESS
        );
    }
    @Override
    public void handle(StreamTableEnvironment tableEnv) {
        //  读取 ODS 数据
        this.readOdsDb(tableEnv, FlinkConstant.TOPIC_DWD_TRADE_REFUND_PAYMENT_SUCCESS);

    }
}
